package main

import (
	"context"
	"time"

	"go.opentelemetry.io/collector/model/otlpgrpc"
	"go.opentelemetry.io/collector/model/pdata"
	semconv "go.opentelemetry.io/collector/model/semconv/v1.5.0"
	"google.golang.org/grpc"
)

func main() {
	conn, err := grpc.Dial("localhost:8200", grpc.WithInsecure(), grpc.WithBlock())
	if err != nil {
		panic(err)
	}
	defer conn.Close()

	client := otlpgrpc.NewLogsClient(conn)
	newLog := func(body interface{}) pdata.Logs {
		logs := pdata.NewLogs()
		resourceLogs := logs.ResourceLogs().AppendEmpty()
		logs.ResourceLogs().At(0).Resource().Attributes().InsertString(
			semconv.AttributeTelemetrySDKLanguage, "go",
		)
		instrumentationLogs := resourceLogs.InstrumentationLibraryLogs().AppendEmpty()
		otelLog := instrumentationLogs.Logs().AppendEmpty()
		otelLog.SetTraceID(pdata.NewTraceID([16]byte{1}))
		otelLog.SetSpanID(pdata.NewSpanID([8]byte{2}))
		otelLog.SetName("doOperation()")
		otelLog.SetSeverityNumber(pdata.SeverityNumberINFO)
		otelLog.SetSeverityText("Info")
		otelLog.SetTimestamp(pdata.NewTimestampFromTime(time.Now()))
		otelLog.Attributes().InsertString("key", "value")
		otelLog.Attributes().InsertDouble("key", 1234)

		switch b := body.(type) {
		case string:
			otelLog.Body().SetStringVal(b)
		case int:
			otelLog.Body().SetIntVal(int64(b))
		case float64:
			otelLog.Body().SetDoubleVal(float64(b))
		case bool:
			otelLog.Body().SetBoolVal(b)
		}
		return logs
	}

	_, err = client.Export(context.Background(), newLog("my log message"))
	if err != nil {
		panic(err)
	}
	_, err = client.Export(context.Background(), newLog(12334))
	if err != nil {
		panic(err)
	}
}